package com.cobra.rdd.operator.transform

import org.apache.spark.{SparkConf, SparkContext}

//排序
object Spark18_RDD_Operator_Transform_SortBy {
  def main(args: Array[String]): Unit = {
    val sparkConf = new SparkConf().setMaster("local[*]").setAppName("Spark18_RDD_Operator_Transform_SortBy")
    val sc = new SparkContext(sparkConf)
//    val rdd = sc.makeRDD(List(6,2,5,4,3,1),2)
//    //排序的话分区也不变的
//    val newRDD = rdd.sortBy(num => num)
//    newRDD.saveAsTextFile("output")

    val rdd = sc.makeRDD(List(("1",1),("11",2),("2",3)),2)
    val newRDD = rdd.sortBy(t => t._1.toInt, false)
    newRDD.collect().foreach(println)
    sc.stop()
  }
}
